package org.cainiao.basic.reactive.source;

public interface Channel {

    void poll(long n);

    void cancel();

    void close();

}
